package neu.soft.rocketmq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface InputBinding
{
    @Input("input-common-1")
    SubscribableChannel inputCommon1();

    @Input("input-common-2")
    SubscribableChannel inputCommon2();

    @Input("input-common-3")
    SubscribableChannel inputCommon3();

    @Input("input-common-4")
    SubscribableChannel inputCommon4();

    @Input("input-common-5")
    SubscribableChannel inputCommon5();

    @Input("output-common-1")
    MessageChannel outputCommon1();
}
